10.3. Usage 用法

10.3.1. 简单例子

使用 JPA 变量的例子可以在 JPAVariableTest 中找到。我们将会一步一步的解释 JPAVariableTest.testUpdateJPAEntityValues。

首先，我们需要创建一个基于 META-INF/persistence.xml 的EntityManagerFactory 作为我们的持久化单元。它包含持久化单元中所有的类和一些供应商特定的配置。

我们将使用一个简单的实体作为测试，其中包含有一个 id 和 String 类型的 value 属性，这也将会被持久化。在允许测试之前，我们创建一个实体并且保存它。

  1. @Entity(name = "JPA_ENTITY_FIELD")
  2. public class FieldAccessJPAEntity {
  4.   @Id
  5.   @Column(name = "ID_")
  6.   private Long id;
  8.   private String value;
  10.   public FieldAccessJPAEntity() {
  11.     // Empty constructor needed for JPA
  12.   }
  14.   public Long getId() {
  15.     return id;
  16.   }
  18.   public void setId(Long id) {
  19.     this.id = id;
  20.   }
  22.   public String getValue() {
  23.     return value;
  24.   }
  26.   public void setValue(String value) {
  27.     this.value = value;
  28.   }
  29. }

我们开始一个新的流程实例，添加实体作为变量。与其它的变量一样，它们存储在引擎的持久存储区。当下次这个变量被请求，它会从基于类和Id的存储的 EntityManager 中加载。

  1. Map<String, Object> variables = new HashMap<String, Object>();
  2. variables.put("entityToUpdate", entityToUpdate);
  4. ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("UpdateJPAValuesProcess", variables);

在我们的流程定义的第一个节点包含一个 serviceTask 将调用方法 在 entityToUpdate 上 setValue，它解析为 JPA 变量，我们启动流程实例并将从相关联的当前引擎的上下文“EntityManager”进行加载。

  1. <serviceTask id='theTask' name='updateJPAEntityTask'
  2.   activiti:expression="${entityToUpdate.setValue('updatedValue')}" />

当 service-task 完成后，流程实例等在流程定义中定义的 userTask，这使我们能够检查流程实例。在这一点上，EntityManager 已刷新并更改到实体已经被推到数据库。当我们得到变量 entityToUpdate 值时，它再次加载，我们得到实体，并将实体中的属性 value 设置到 updatedValue 。

  1. // Servicetask in process 'UpdateJPAValuesProcess' should have set value on entityToUpdate.
  2. Object updatedEntity = runtimeService.getVariable(processInstance.getId(), "entityToUpdate");
  3. assertTrue(updatedEntity instanceof FieldAccessJPAEntity);
  4. assertEquals("updatedValue", ((FieldAccessJPAEntity)updatedEntity).getValue());

10.3.2. 查询 JPA 处理变量

可以查询 ProcessInstances 和 Execution 包含 JPA 实体作为变量值。注意 只有 在 ProcessInstanceQuery 和 ExecutionQuery ，variableValueEquals(name, entity) 是支持 JPA 实体的 。
方法 variableValueNotEquals, variableValueGreaterThan, variableValueGreaterThanOrEqual, variableValueLessThan和 variableValueLessThanOrEqual 不支持，并且当一个 JPA 实体传递作为值时，会抛出 ActivitiException。

  1. ProcessInstance result = runtimeService.createProcessInstanceQuery()
  2.     .variableValueEquals("entityToQuery", entityToQuery).singleResult();

10.3.3. 高级例子：使用 Spring bean 和 JPA

JPASpringTest 例子可以在 activiti-spring-examples 中找到。它的使用场景如下：

  • 存在一个使用 JPA 实体的 Spring bean，用于存储贷款请求。
  • 使用 Activiti，我们可以利用那些由现有的 bean 获得的已有的实体，并将其作为变量在流程中使用。
    流程是按以下步骤进行定义的：
    • 服务任务，利用已有的 LoanRequestBean 使用启动流程时接收的变量（比如，可以来源于开始的表单）来创建新的 LoanRequest。使用 activiti:resultVariable（它以一个变量来存储表达式结果）将创建出来的实体以变量进行存储。
    • 用户任务，让经理查看请求，批准/不批准，结果存储到一个 boolean 类型的变量 approvedByManager 上。
    • 服务任务，用来更新贷款请求实体以使该实体与流程同步。
    • 根据实体属性 approved 的值，利用排他分支来决定下一步选择哪条路径：当请求被批准时，流程将结束；否则，会另有一个任务（发送拒绝信），这样就可以由拒绝信手动地通知用户了。

请注意此流程不包含任何表单，所以其只用于单元测试

Usage 使用 - 图1

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <definitions id="taskAssigneeExample"
  3.   xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL"
  4.   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  5.   xmlns:activiti="http://activiti.org/bpmn"
  6.   targetNamespace="org.activiti.examples">
  8.   <process id="LoanRequestProcess" name="Process creating and handling loan request">
  9.     <startEvent id='theStart' />
  10.     <sequenceFlow id='flow1' sourceRef='theStart' targetRef='createLoanRequest' />
  12.     <serviceTask id='createLoanRequest' name='Create loan request'
  13.       activiti:expression="${loanRequestBean.newLoanRequest(customerName, amount)}"
  14.       activiti:resultVariable="loanRequest"/>
  15.     <sequenceFlow id='flow2' sourceRef='createLoanRequest' targetRef='approveTask' />
  17.     <userTask id="approveTask" name="Approve request" />
  18.     <sequenceFlow id='flow3' sourceRef='approveTask' targetRef='approveOrDissaprove' />
  20.     <serviceTask id='approveOrDissaprove' name='Store decision'
  21.       activiti:expression="${loanRequest.setApproved(approvedByManager)}" />
  22.     <sequenceFlow id='flow4' sourceRef='approveOrDissaprove' targetRef='exclusiveGw' />
  24.     <exclusiveGateway id="exclusiveGw" name="Exclusive Gateway approval" />
  25.     <sequenceFlow id="endFlow1" sourceRef="exclusiveGw" targetRef="theEnd">
  26.       <conditionExpression xsi:type="tFormalExpression">${loanRequest.approved}</conditionExpression>
  27.     </sequenceFlow>
  28.     <sequenceFlow id="endFlow2" sourceRef="exclusiveGw" targetRef="sendRejectionLetter">
  29.       <conditionExpression xsi:type="tFormalExpression">${!loanRequest.approved}</conditionExpression>
  30.     </sequenceFlow>
  32.     <userTask id="sendRejectionLetter" name="Send rejection letter" />
  33.     <sequenceFlow id='flow5' sourceRef='sendRejectionLetter' targetRef='theOtherEnd' />
  35.     <endEvent id='theEnd' />
  36.     <endEvent id='theOtherEnd' />
  37.   </process>
  39. </definitions>

虽然上面的例子很简单，但确实展示出了结合 Spring 和参数化方法表达式来使用 JPA 的强大。此流程根本不需要定制 java
代码（当然了，除 Spring bean 外），大大加速了部署